package org.example

import org.apache.spark.{SparkConf, SparkContext}

object lx1 {
  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setAppName("lx1").setMaster("local[*]");
    val sc = new SparkContext(conf);
    var rdd1=sc.textFile("data/lx1");
    var len=rdd1.filter(lens=>lens.trim.length>0)
    var rdd2=len.map(x=>(x.toInt,1)).sortByKey().map(_._1)
    var rdd3=rdd2.repartition(1);
    var i=0;
    var rdd4=rdd3.map(x=>{
      i+=1
      (i,x)
    })
    rdd4.foreach(println)
  }

}
